const axios = require('axios');

// 查询批次状态
async function checkBatchStatus() {
  try {
    console.log('🔍 查询批次处理状态...');
    
    // 查询批次列表
    const batchResponse = await axios.get('http://localhost:7001/api/v1/plugin/data/batches');
    console.log('📋 批次列表:', JSON.stringify(batchResponse.data, null, 2));
    
    // 获取最新批次ID
    if (batchResponse.data.data && batchResponse.data.data.length > 0) {
      const latestBatch = batchResponse.data.data[0];
      console.log('\n📊 最新批次信息:');
      console.log('  批次ID:', latestBatch.batchId);
      console.log('  数据类型:', latestBatch.dataType);
      console.log('  状态:', latestBatch.status);
      console.log('  数据条数:', latestBatch.count);
      console.log('  已处理条数:', latestBatch.processedCount);
      console.log('  失败条数:', latestBatch.failedCount);
      
      // 查询具体批次状态
      const statusResponse = await axios.get(`http://localhost:7001/api/v1/plugin/data/status?batchId=${latestBatch.batchId}`);
      console.log('\n📈 批次详细状态:', JSON.stringify(statusResponse.data, null, 2));
    }
  } catch (error) {
    console.error('❌ 查询批次状态失败:', error.message);
    if (error.response) {
      console.error('📋 错误详情:', error.response.data);
    }
  }
}

checkBatchStatus();